package com.ruoyi.stream.framework.model.request;

import com.ruoyi.stream.framework.core.protocol.SKAProtocolContext;
import com.ruoyi.stream.framework.core.protocol.StreamAliveRequest;
import com.ruoyi.stream.framework.core.protocol.StreamAliveResponse;
import com.ruoyi.stream.framework.model.StreamServiceEndpointHandler;
import com.ruoyi.stream.framework.model.configBuilder.IOTaskConfig;
import com.ruoyi.stream.framework.model.configBuilder.IOTaskConfigBuilder;
import io.netty.channel.ChannelHandlerContext;

public abstract class RequestProcessor {

    private SKAProtocolContext context;

    private StreamServiceEndpointHandler handler;

    private ChannelHandlerContext ctx;
    public abstract void handleRequestResource(StreamAliveResponse response);

    public abstract void  handleReady(StreamAliveResponse response);

    public abstract void handleRefuse(StreamAliveRequest request, StreamAliveResponse response);

    public SKAProtocolContext getContext() {
        return context;
    }

    public void setContext(SKAProtocolContext context) {
        this.context = context;
    }

    public StreamServiceEndpointHandler getHandler() {
        return handler;
    }

    public void setHandler(StreamServiceEndpointHandler handler) {
        this.handler = handler;
    }

    public ChannelHandlerContext getCtx() {
        return ctx;
    }

    public void setCtx(ChannelHandlerContext ctx) {
        this.ctx = ctx;
    }
}
